package com.wyedu.qqOfflineMessage;

import com.wyedu.qqcommon.Message;
import com.wyedu.qqcommon.MessageType;

import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class MessageQueue {
  private static HashMap<String, BlockingQueue<Message>>map = new HashMap<>();
  //添加该离线用户方法
/**
 * 1.该用户存在
 * 2.该用户不存在
 */
    public static void AddOfflineMessage(String id, Message message) throws InterruptedException {
        if(map.getOrDefault(id,null) == null){
            //如果为空说明该用户不存在
            map.put(id,new LinkedBlockingQueue<>());
        }
           map.get(id).offer(message);
    }
    public static BlockingQueue<Message> getMessageQueue(String id){
            //返回该队列
             return map.remove(id);//如果没有默认返回null
    }

}
